CSharpTest.Net
Enqueue Method
See Also  Example Send Feedback Download Help File
CSharpTest.Net.Library Assembly > CSharpTest.Net.Threading Namespace > WorkQueue<T> Class : Enqueue Method

instance

Glossary Item Box

Enqueues a task

Syntax

Visual Basic (Declaration) 
Public Sub Enqueue( _
   ByVal instance As T _
) 
C# 
public void Enqueue( 
   T instance
)

Parameters

instance

Exceptions

ExceptionDescription
System.ObjectDisposedExceptionThe exception that is thrown when an operation is performed on a disposed object.

Example

Library/Library.Test/TestWorkQueue.cs

C#Copy Code
int[] counter = new int[1];
using (WorkQueue<int[]> worker = new WorkQueue<int[]>(ProcessOne, Math.Max(2, Environment.ProcessorCount)))
{
    for (int i = 0; i < 1000; i++)
        worker.Enqueue(counter);
    worker.Complete(false, 10);
}
Assert.AreNotEqual(0, counter[0]);
VB.NETCopy Code
Dim counter As Integer() = New Integer(1) {}
Using worker As New WorkQueue(Of Integer())(ProcessOne, Math.Max(2, Environment.ProcessorCount))
    Dim i As Integer = 0
    While i < 1000
        worker.Enqueue(counter)
        System.Math.Max(System.Threading.Interlocked.Increment(i),i - 1)
    End While
    worker.Complete(False, 10)
End Using
Assert.AreNotEqual(0, counter(0))

Requirements

Target Platforms: Windows XP, Windows Server 2003, Windows Vista, Windows Server 2008, Windows 7

See Also

Reference

WorkQueue<T> Class
WorkQueue<T> Members

Used By

ThreadedBTreeTest.TestErrorsOnInsertAndDelete()
ThreadedBTreeTest.TestConcurrentCreateReadUpdateDelete8000()
Boolean SecureTransfer.Client.Upload(String,Int64,Stream)
WorkQueue.Enqueue(Action,T)

Source Code

Library/Threading/WorkQueue.cs

Generated with Document! X 2011 by Innovasys